

package com.hazelcast.jet.pipeline;

import javax.annotation.Nonnull;

/**
 * A pipeline stage that doesn't allow any downstream stages to be attached
 * to it. Corresponds to a data sink.
 *
 * @since Jet 3.0
 */
public interface SinkStage extends Stage {

    @Nonnull
    @Override
    SinkStage setLocalParallelism(int localParallelism);

    @Nonnull
    @Override
    SinkStage setName(@Nonnull String name);
}
